package com.matrix.activemq.topic;

import javax.jms.JMSException;

public class ConsumerTest implements Runnable{
    static Thread t1 = null;

    public static void main(String[] args) {
        t1 = new Thread(new ConsumerTest());
        t1.setDaemon(false);
        t1.start();
    }

    public void run() {
        try {
            ConsumerTool consumerTool = new ConsumerTool();
            consumerTool.consumerMessage();
            while (consumerTool.isConnection) {
            }
        } catch (JMSException e) {
            e.printStackTrace();
        }
    }
}
